package com.lkx.kafka.monitor.dto;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class TopicMetrics {

    private String topicName;
    private int partitionCount;
    private int replicaCount;
    private double produceRate; // 消息/秒
    private double consumeRate; // 消息/秒
    private long backlog; // 积压消息数
    private String status; // 健康/警告/异常
    private long retentionMs; // 消息保留时间(ms)
    private boolean isInternal; // 是否内部主题

}